package cn.sheep.dolphin.etl

import cn.sheep.dolphin.common.DolphinAppComm
import org.apache.spark.sql.SQLContext

/**
  * author: old sheep
  * QQ: 64341393 
  * Created 2018/11/28
  */
object Sql4Parquet {

	def main(args: Array[String]): Unit = {

		val sc = DolphinAppComm.createSparkContext("测试parquet读取")

		val sqlc = new SQLContext(sc)
		val dataFrame = sqlc.read.parquet("F:\\dolphin\\parquet")

		dataFrame.show(100)

		sc.stop()

	}

}
